package jrain.iot.server.mqtt.utils;

import jrain.fw.core.business.BusinessRequest;
import jrain.fw.core.business.BusinessResponse;
import jrain.fw.core.utils.FwUtils;

public class SendUtils {

	public static BusinessResponse sendMsg(String userName, String msg) {
		BusinessRequest request = new BusinessRequest();
		request.setService("MqttSimpleCtxService");
		request.setMethod("publish");
		request.putData("key", userName);
		request.putData("value", msg);
		return FwUtils.getBusinessInnerClient().doSync(request);
	}
}
